package com.lm.flink.property;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

import java.io.Serializable;

@Data
@Configuration
@ConfigurationProperties(prefix = "flink.kafka")
public class KafkaProperty implements Serializable {
    private String bootstrapServers;
    private String topic;
    private String groupId;
}
